package com.rpc.test.client.flow;

import rpc.core.BaseAsyncFlow;
import rpc.core.InvokeInfo;
import rpc.core.annotations.Flow;

@Flow("consumerapi.hi")
public class Flow1 extends BaseAsyncFlow {

  @Override
  public void enter() {
    InvokeInfo invokeInfo = this.invokeFeature("consumerapi.flow2", req);
    this.invoke(this::retRes, invokeInfo);
  }
}
